package com.demo.kafka.entity;

import lombok.Getter;

import java.util.UUID;

@Getter
public class KafkaMessage {
    private final String msgId;
    private Object payload;

    public KafkaMessage() {
        msgId = UUID.randomUUID().toString().replaceAll("-", "");
    }

    public void setPayload(Object payload) {
        this.payload = payload;
    }
}
